package com.ucode.springboot.starter.canal.event;

import com.alibaba.otter.canal.protocol.CanalEntry;

/**
 * 表数据改变事件监听接口
 * @author: liliang
 * @date: 2020年2月27日 下午2:53:03
 */
@FunctionalInterface
public interface CanalEventListener {

    /**
     * 处理事件(数据库的操作)
     * @author liliang
     * @date 2020年2月27日
     * @param destination 指令
     * @param schemaName 库实例
     * @param tableName 表名
     * @param rowChange 变更行详细参数
     */
    void onEvent(String destination, String schemaName, String tableName, CanalEntry.RowChange rowChange);
    
}
